#!/bin/sh
# PCP QA Test No. 1286
# Exercise the BCC PMDA netproc hits module - install, remove and values.
#
# Copyright (c) 2020 Red Hat.
#

seq=`basename $0`
echo "QA output created by $seq"

. ./common.bcc

_pmdabcc_check
_pmdabcc_require_kernel_version 4 6
which ss >/dev/null 2>&1 || _notrun "No ss binary installed"

status=1       # failure is the default!
signal=$PCP_BINADM_DIR/pmsignal
$sudo rm -rf $tmp.* $seq.full

# The netproc BCC module uses the lookup_or_try_init() method that was
# introduced in bcc v0.12.0 (released 11 Dec 2019), so determine the
# bcc version and _notrun as appropriate.
#
# Like most things in Pythonland, it would appear there are many (more
# that 6 according to google) ways to determine the version of a module,
# but none of them are guaranteed to work!  The recipe below seems robust
# for the bcc module.
#
cat <<'End-of-File' >$tmp.py
import bcc
print(bcc.__version__)
End-of-File
echo "bcc version ..." >>$seq.full
version=`pmpython $tmp.py 2>>$seq.full`
echo "$version" >>$seq.full
case "$version"
in
    '')
	    # failed to extract version ($seq.full may help) ... but punt
	    # on running the test
	    ;;

    0.0.*|0.1[0-1].*)
	    _notrun "need version >= 0.12.0 (not $version) for bcc Python module"
	    ;;
esac

_pid_filter()
{
    sed \
      -e "s/$1/SERVERPID/g" \
      -e "s/$2/CLIENTPID/g" \
      -e '/inst \[[0-9]/d' \
    #end
}

_prepare_pmda bcc
trap "_pmdabcc_cleanup; exit \$status" 0 1 2 3 15
_stop_auto_restart pmcd

# real QA test starts here
cat <<EOF | _pmdabcc_install
[pmda]
modules = netproc
prefix = bcc.
[netproc]
module = netproc
cluster = 40
pmda_indom_cache = False
remove_stopped_processes = False
EOF
_pmdabcc_wait_for_metric

# Generate system activity for the BCC netproc module
$python src/bcc_netproc.py server >> "$seq.full" &
server_pid=$!

# wait for server to listen on specified port
for i in `seq 1 10`; do ss -lnt | grep -q :1234 && break; sleep 1; done
if [ $i -ge 10 ]; then
    echo "Server didn't open tcp/1234 in time, test failed"
    exit 1
fi

$python src/bcc_netproc.py client >> "$seq.full" &
client_pid=$!

wait ${client_pid}
wait ${server_pid}
echo "server PID: ${server_pid}" >> "$seq.full"
echo "client PID: ${client_pid}" >> "$seq.full"

for metric in bcc.proc.io.net.perpid.tcp.send.calls \
              bcc.proc.io.net.perpid.tcp.send.bytes \
              bcc.proc.io.net.perpid.tcp.recv.calls \
              bcc.proc.io.net.perpid.tcp.recv.bytes \
              bcc.proc.io.net.perpid.udp.send.calls \
              bcc.proc.io.net.perpid.udp.send.bytes \
              bcc.proc.io.net.perpid.udp.recv.calls \
              bcc.proc.io.net.perpid.udp.recv.bytes
do
    echo && echo && echo "=== report metric values for $metric ==="
    pminfo -dfmtT $metric 2>&1 | tee -a $seq.full \
    | _pid_filter ${server_pid} ${client_pid} \
    | sort # sort to fix the non deterministic instance order

done

_pmdabcc_remove

status=0
exit
